const mysql = require('mysql')
module.exports = {
  // 数据库配置
  config: {
    host: 'localhost',
    port: '3306',
    user: 'root',
    password: '',
    database: '2204fitness'
  },
  // mysql连接池
  sqlConnect: function (sql, sqlArr, callback) {
    var pool = mysql.createPool(this.config)
    pool.getConnection((err, conn) => {
      console.log('pool succ');
      if (err) {
        console.log('pool failed');
        return;
      }
      // 事件驱动回调
      conn.query(sql, sqlArr, callback);
      // 释放链接
      conn.release();
    })
  },
  // promise回调
  SySqlConnect: function (sySql, sqlArr) {
    return new Promise((resolve, reject) => {
      var pool = mysql.createPool(this.config)
      pool.getConnection((err, conn) => {
        console.log('pool succ');
        if (err) {
          reject(err)
        } else {
          // 事件驱动回调
          conn.query(sySql, sqlArr, (err, data) => {
            if (err) {
              reject(err);
            } else {
              resolve(data);
            }
          });
          // 释放链接
          conn.release();
        }
      })
    }).catch((err) => {
      console.log(err)
    })
  }
}